package cn.me.alphamq.client.consumer;

import cn.me.alphamq.common.entity.Message;

import java.util.List;

/**
 * 并发消息消费监听器
 *
 * @author f
 */
public class ConcurrentMessageConsumeListener implements MessageConsumeListener {
    @Override
    public ConsumeResult consume(List<Message> messageList) {
        // TODO 之后可以考虑实现
        return null;
    }
}
